import com.aliyun.odps.udf.ExecutionContext;
import com.aliyun.odps.udf.UDFException;
import com.aliyun.odps.udf.UDTF;
import com.aliyun.odps.udf.annotation.Resolve;

// TODO define input and output types, e.g. "string,string->string,bigint".
@Resolve({"*->String,String"})
public class MyUDTFLocal extends UDTF {

    @Override
    public void process(Object[] args) throws UDFException {
        // TODO
        int hours = 0;
        for (Object obj : args) {
            String col = obj.toString();
            forward(hours + "时",col);
            hours = hours + 2;
        }
    }



}